package com.sjk.flink.pojo;

import lombok.Data;

@Data
public class OutPutPojo {


    private String tableName;

    private String topic;

    private String json;

    private int  clayer_partition;

    private long  clayer_offset;

    private Long  clayer_ts;
}
